<?php

declare(strict_types=1);

namespace app\jobs\queue;

use think\facade\Queue;

/**
 * 生产
 */
class OwnsQueue
{
    /**
     * 队列消息推送
     * @param string $class 消费类名
     * @param array $data 发布任务时自定义数据
     */
    public static function push(string $class, array $data): void
    {
        Queue::push($class, $data, 'owns_tp_queue');
    }
    
    /**
     * 队列消息推送
     * @param string $class 消费类名
     * @param array $data 发布任务时自定义数据
     * @param integer $delay 5s后执行
     */
    public static function later(string $class, array $data, int $delay = 5): void
    {
        Queue::later($delay, $class, $data, 'owns_td_queue');
    }
}
